草庐IT

CountDownLatch和ExecutorService 线程池cachedThreadPool.submit

全部标签

java - 从 Java 内存模型的角度理解为什么在构造函数中启动线程是不安全的

这个问题在这里已经有了答案:Whyshouldn'tIuseThread.start()intheconstructorofmyclass?(2个答案)关闭3年前。根据JavaConcurrencyinPractice,在类构造函数中启动线程是危险的。原因是在对象完全构造之前,this将this指针暴露给另一个线程。尽管这个话题在之前的许多StackOverflow问题中都有讨论,但我仍然难以理解为什么这是一个如此令人担忧的问题。特别是,我希望从Java内存模型的角度澄清在构造函数内启动线程是否会导致内存一致性问题。让我举一个具体的例子来说明我想做的事情。(这段代码的期望输出是将数字2

java - Java MulticastSocket 是线程安全的吗?

我有两个线程。第一个在循环中发送带有MulticastSocket的数据报;第二个线程在循环中使用相同的MulticastSocket实例接收数据报。它似乎工作正常,但我仍然有疑问。这两个线程可以使用同一个MulticastSocket实例吗?MulticastSocket在发送/接收方法调用方面是线程安全的吗? 最佳答案 发送和接收DatagramSocket方法都在发送/接收数据报包上同步。换句话说,如果您使用相同的数据报包从两个不同的线程发送和接收,这两个方法将同步,因为它们将使用相同的对象作为同步token。看了Datagr

java - 这段代码是线程安全的吗?

我想处理客户请求流。每个请求都有其特殊的类型。首先我需要为该类型初始化一些数据,然后我可以开始处理请求。client类型第一次来的时候,我只是初始化对应的数据。在此之后,将使用该数据处理该类型的所有以下请求。我需要以线程安全的方式执行此操作。这是我写的代码。它是线程安全的吗?publicclassTest{privatestaticMapclientTypesInitiated=newConcurrentHashMap();/*toprocessclientrequestweneedtocreatecorrespondingclienttypedata.onthefirstsignal

Java ExecutorService 和 ThreadPoolExecutor

我遇到了一个奇怪的问题。我正在尝试使用生产者/消费者模型,如果我在这里做错了什么,请提出建议。当我使用固定线程4的ExecutorService时,我从来没有得到任何异常并且程序运行但是当我使用ThreadPoolExecutor时,它给了我异常。无法找出错误是什么!请指教!ExecutorService代码:ArrayBlockingQueuelist=newArrayBlockingQueue(2);ThreadFactorythreadFactory=Executors.defaultThreadFactory();ExecutorServicethreadPool=Execut

Java - 运行一个线程两次

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。要求提供代码的问题必须表现出对所解决问题的最低限度理解。包括尝试过的解决方案、为什么它们不起作用,以及预期结果。另请参阅:StackOverflowquestionchecklist关闭9年前。ImprovethisquestionFromanotherpost:IfaThreadneedstoberunmorethanonce,thenoneshouldmakeannewinstanceoftheThreadandcallstartonit.这是怎么做到的?

Java - 等待第三方线程完成

我有一个将运行第三方库的线程,该库也将运行自己的线程。当我的Thread的run方法结束时,第三方Threads还没有结束。那么,在这些外部线程仍在运行之前,保持我的线程的最佳方法是什么? 最佳答案 如果您是一个应用程序并且不必担心SecurityManager的限制,并且如果您准备在第三方代码更新时偶尔修改您的代码,您可以使用ThreadGroup的功能来遍历线程并通过名称或包含它们的线程组来识别它们。一旦找到线程,监视它们直到它们完成或根据需要使用Thread.join()是一项简单的工作。例如,这里有一些工作代码可以转储JVM

java - 如果未调用 notify(),等待线程会发生什么情况?

如果未调用notify(),等待线程会发生什么情况?这是虚假唤醒吗? 最佳答案 如果等待线程未通过调用notify()或notifyAll()通知在所述线程正在等待的对象上,则可能发生以下任何一种情况:Thread一直在对象的等待池中等待如果指定了超时并且时间过去了,Thread将变为runnable线程被中断并再次变得可运行Thread完全没有的原因被唤醒,即它既没有被通知也没有被中断最后一种情况被称为虚假唤醒,这也是为什么Thread唤醒时应该始终检查它是否正在等待的条件的原因之一因为是真的还是假的。如果没有,Thread应该调

线程之间的 Java 同步列表。最佳实践

当某些更改发生时,我正在制作一个数据库日志记录引擎。这些更改被推送到一个线程中的队列中,该线程每50毫秒处理队列中的25个LogObjects。我正在考虑使用Collections.synchronizedList()来保存我仍然需要在线程中处理的对象。主应用程序线程通过ThreadObjInstance.LogList.add(newLogObject("Somethingtolog");将LogObjects插入列表,在线程中我执行LogObjectx=LogList。shift();来处理它。但是我觉得可能有更好的方法来做到这一点,或者这是一种完全可以接受的方法?或者我应该针对他

java - EJB 中的多线程

我正在学习EJB,到目前为止我已经读到EJB中不允许使用多线程,因为容器应该关心线程安全并让开发人员只关注业务逻辑,所以基本上意味着EJB确保只有一个线程可以同时访问Sessionbean中的方法。当我们有许多用户访问EJB中的同一个方法时会发生什么?容器是序列化访问,还是创建不同的bean实例,每个线程一个?谁能解释一下这方面的政策是什么?另外我有点困惑,为什么如果不允许多线程,那么我们不能创建自己的线程,为什么我们有这个@Asynchronous注释? 最佳答案 是的,它创建了多个实例,并将它们集中在一起。查看officialO

java - 在 Java 中创建太多线程

我在我的Java应用程序中使用线程来部分获取数据(使用网络调用)。我有一个方法(不在线程类中),它创建一个给定大小的线程池(最大10-15)并将它们用于网络调用,我多次调用该方法来自一个循环。当我在慢速机器(3GBRAM,Pentium-IV)上运行此应用程序时,一切正常,但当我在iMac(32GBRAM,i7处理器)上运行它时,它创建了太多线程,有时大约2,500次并抛出内存不足错误。我怀疑JVM没有在完成后立即将已完成的线程放回池中,因此它正在创建新线程。即使在iMac上,如果我保持Thread.sleep(1000);在我上面提到的for循环中,一切正常。虽然创建了大约900个线